package com.dmz.java.reactive;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class ReactiveTest {
    public void testMono(){
        Mono.just(1);
    }
    public void testFlux(){
        Flux.just(1,2).filter(item->item>1).subscribe(item->{
            System.out.println(item);
        });
    }
}
